#include "app_mqtt.h"
#include "log/log.h"
#include <unistd.h>

// 接收到远程消息的回调函数
int recv_callback(char *json) {
    log_debug("处理接收的远程消息，消息内容：%s\n", json);
    return 0;
}

int main(int argc, char const *argv[])
{
    // 初始化mqtt客户端
    app_mqtt_init();

    // 注册接收到远程消息的回调函数
    app_mqtt_registerRecvCallback(recv_callback);

    // 发送远程消息
    app_mqtt_sendMes("{\"conn_type\":1,\"id\":\"XY\",\"msg\":\"abcd\"}");

    // 等待100秒
    sleep(100);

    // 关闭mqtt客户端
    app_mqtt_deinit();

    return 0;
}